package com.youxin.dataStream.commonApi;

/**
 * 流处理常用api
 * map   单行处理
 * flatMap   压平map   相当于  map().flat()
 * filter    过滤
 * keyBy 按照某个进行聚合     dataSet里面使用group
 * reduce  当前值和最后的值行进处理
 * aggregations：sum(),min(),max()等   例如: keyBy(0).sum(1)
 *
 * window相关的操作
 *
 * union  将多个流进行合并
 * connect 只能两个流进行合并  合并后结合coMap进行操作   （感觉很鸡肋）
 * split 将一个流切分为多个流   后面可以跟select操作获取哪些部分的流数据
 *
 *
 */
public class StreamApi {
}
